﻿using KinonekoSoftware.ArkSpark.Core.Delegates;

namespace KinonekoSoftware.ArkSpark.Core
{
    public interface IArkSparkMQ
    {
        void OnNext(IArkSparkEvent  msg);
        
        /// <summary>
        /// 
        /// </summary>
        MessageHandler ForwardHandler { get; set; }
    }
}